C:/Projekte/RAIS/InstallRAISDB/Installer1.cs

Go to the documentation of this file.

using System;
using System.Collections;
using System.Collections.Generic;
using System.ComponentModel;
using System.Configuration.Install;
using System.Linq;
using System.IO;
using System.Data.SqlClient;
using System.Xml;
using Microsoft.Win32;
using System.IO.Compression;
using System.Windows.Forms;

namespace InstallRAISDB
{
    [RunInstaller(true)]
    public partial class Installer1 : Installer
    {
        TextWriter log;
        string connectionString;
        IDictionary _savedState;

        public Installer1()
        {
            InitializeComponent();
        }
        protected override void OnAfterInstall(IDictionary savedState)
        {
            _savedState = savedState;
            base.OnAfterInstall(savedState);

            using (FileStream file = File.Open("c:\\log.txt", FileMode.OpenOrCreate))
            {
                if (File.Exists(Context.Parameters["targetdir"] + "\\flag"))
                {
                    var result = MessageBox.Show("It seems that there is already an installation of RAIS on this machine. \r\n\r\n If you continue, an existing Database could be overwritten! \r\n\r\n Do you want to continue ?  ", "Caution",
                                    MessageBoxButtons.YesNo,
                                    MessageBoxIcon.Question);

                    if (result == DialogResult.No)
                    {
                        MessageBox.Show("RAIS Installation will finish, but NO database will be installed ! ", "Caution",
                                    MessageBoxButtons.OK,
                                    MessageBoxIcon.Information);
                        return;
                    }
                }

                File.Create(Context.Parameters["targetdir"] + "\\flag").Close();

                UnpackDB();
                using (log = new StreamWriter(file))
                {
                    try
                    {
                        connectionString = string.Format("Data Source={0};Integrated Security=True;", Context.Parameters["db"]);
                        CreateDataBase();
                        log.WriteLine("CreateDataBase()");
                        AddUser();
                        log.WriteLine("AddUser()");
                        CorrectWebConfig();
                        log.WriteLine("CorrectWebConfig()");
                        InstallSelectedLanguage();
                        log.WriteLine("InstallSelectedLanguage()");
                    }
                    catch (Exception e)
                    {
                        log.WriteLine(e.Message);
                        log.WriteLine(e.StackTrace);
                        throw e;
                    }
                }
            }
        }

        protected override void OnAfterUninstall(IDictionary savedState)
        {
            base.OnAfterUninstall(savedState);
            using (FileStream file = File.Open("c:\\log.txt", FileMode.OpenOrCreate))
            {
                using (log = new StreamWriter(file))
                {
                    File.Delete(Context.Parameters["targetdir"] + "\\RAIS");
                    File.Delete(Context.Parameters["targetdir"] + "\\flag");
                }
            }
        }

        private void AddUser()
        {
            using (SqlConnection connection = new SqlConnection(connectionString))
            {
                string commandText = string.Format(" IF EXISTS(select * from sys.syslogins where name = '{0}') DROP LOGIN [{0}]" +
                            "   CREATE LOGIN [{0}] WITH PASSWORD='{1}', CHECK_POLICY=OFF", Context.Parameters["login"],
                                        Context.Parameters["pass"],
                                        Context.Parameters["catalog"]);
                connection.Open();
                SqlCommand command = new SqlCommand(commandText, connection);
                log.WriteLine(commandText);
                command.ExecuteNonQuery();
            }
            string connectionString1 = string.Format("Data Source={0};Initial Catalog={1};Integrated Security=True;", Context.Parameters["db"], Context.Parameters["catalog"]);
            using (SqlConnection connection = new SqlConnection(connectionString1))
            {
                string commandText = string.Format(" IF EXISTS(select * from sys.sysusers where name = '{0}') DROP USER [{0}] " +
                                " CREATE USER [{0}] FOR LOGIN [{0}] WITH DEFAULT_SCHEMA = [dbo] " +
                                " EXEC sp_addrolemember N'db_datareader', N'{0}' " +
                                " EXEC sp_addrolemember N'db_datawriter', N'{0}' " +
                                " EXEC sp_addrolemember N'db_owner', N'{0}' "
                                , Context.Parameters["login"]);
                connection.Open();
                log.WriteLine(commandText);
                SqlCommand command = new SqlCommand(commandText, connection);
                command.ExecuteNonQuery();
            }
        }

        private void CorrectWebConfig()
        {
            string connectionStringConfig = string.Format("Data Source={0};Initial Catalog={1};Persist Security Info=True;User ID={2};Password={3};Min Pool Size=4;Max Pool Size=10;",
                Context.Parameters["db"],
                Context.Parameters["catalog"],
                Context.Parameters["login"],
                Context.Parameters["pass"]);

            XmlDocument webConfig = new XmlDocument();
            string webConfigFile = Context.Parameters["targetdir"] + "\\Web.config";
            webConfig.Load(webConfigFile);

            XmlNode configurationNode = webConfig.SelectSingleNode("//configuration");

            XmlNode connectionStringsNode = configurationNode.SelectSingleNode("//connectionStrings");
            if (connectionStringsNode == null)
                log.WriteLine("//connectionStrings not exists");

            XmlNode addNode = connectionStringsNode.SelectSingleNode("//add[@name='RAISConnectionString']");
            if (addNode == null)
            {
                log.WriteLine("//addNode not exists");
                log.WriteLine(connectionStringsNode.InnerXml);
            }

            webConfig.SelectSingleNode("//configuration/connectionStrings/add[@name='RAISConnectionString']").Attributes["connectionString"].InnerText = connectionStringConfig;
            //webConfig.SelectSingleNode("//configuration/connectionStrings/add[@name='RADEVConnectionString']").Attributes["connectionString"].InnerText = connectionStringConfig;

            if (Context.Parameters["uploadfolder"] != "")
                webConfig.SelectSingleNode("//appSettings/add[@key='UploadDirectory']").Attributes["value"].InnerText = Context.Parameters["uploadfolder"];
            webConfig.SelectSingleNode("//appSettings/add[@key='AdministratorEmailAccount']").Attributes["value"].InnerText = Context.Parameters["adminemail"];
            log.WriteLine(Context.Parameters["adminemail"]);
            log.WriteLine(Context.Parameters["uploadfolder"]);
            webConfig.Save(webConfigFile);
        }

        private void CreateDataBase()
        {
            string checkDataBaseCommand = string.Format("select * from sys.databases where [name]='{0}'", Context.Parameters["catalog"]);

            string restoreCommand =
                    " DECLARE @data_path nvarchar(256)," +
                    " @log_path nvarchar(256); " +
                    " EXEC master.dbo.xp_instance_regread N'HKEY_LOCAL_MACHINE', N'Software\\Microsoft\\MSSQLServer\\MSSQLServer', N'DefaultData', @data_path OUTPUT" +
                    " IF @data_path IS NULL BEGIN" +
                    "    EXEC master.dbo.xp_instance_regread N'HKEY_LOCAL_MACHINE', N'SOFTWARE\\Microsoft\\MSSQLServer\\Setup', N'SQLPath', @data_path OUTPUT" +
                    "    SET @data_path = @data_path + '\\Data\\'" +
                    " END " +
                    " ELSE BEGIN" +
                    "   SET @data_path = @data_path + '\\'" +
                    " END" +

                    " SET @log_path = @data_path + '{0}_log.LDF' " +
                    " SET @data_path = @data_path + '{0}.mdf' " +

                    " RESTORE DATABASE {0}" +
                    " FROM  DISK = '{1}\\RAIS'" +
                    " WITH  FILE = 1, " +
                    " NOUNLOAD, " +
                    " REPLACE, " +
                    " STATS = 10 " +
                    ",  MOVE N'RAIS' TO @data_path " +
                    ",  MOVE N'RAIS_Log' TO @log_path ";


            using (SqlConnection connection = new SqlConnection(connectionString))
            {
                connection.Open();
                string commandText = string.Format(restoreCommand, Context.Parameters["catalog"], Context.Parameters["targetdir"]);
                SqlCommand command = new SqlCommand(checkDataBaseCommand, connection);

                if (command.ExecuteScalar() != null)
                    throw new Exception(string.Format("The DB with name {0} exists on the server {1}. Please, enter an other DB name.", Context.Parameters["catalog"], Context.Parameters["db"]));
                command.CommandTimeout = 240;
                command.CommandText = commandText;
                command.ExecuteNonQuery();
            }
            try
            {
                File.Delete(Context.Parameters["targetdir"] + "\\RAIS");
            }
            catch (Exception) { }
        }
        private void UnpackDB()
        {
            int length;
            byte[] content;
            using (GZipStream compStream = new GZipStream(new FileStream(Context.Parameters["targetdir"] + "\\RAIS.zip", FileMode.Open, FileAccess.Read), CompressionMode.Decompress))
            {
                length = 100000000;
                content = new byte[length];
                length = compStream.Read(content, 0, length);
            }
            using (FileStream fs = new FileStream(Context.Parameters["targetdir"] + "\\RAIS", FileMode.Create, FileAccess.Write))
                fs.Write(content, 0, length);
        }
                
        private void InstallSelectedLanguage()
        {
            string[][] Table = new string[50][];
            Table[1] = new string[] {"[Academic Degree]","[PK Academic Degree ID]","[Degree]"};
            Table[2] = new string[] {"[Action Type]","[PK Action Type ID]","[Action Type Name]"};
            Table[3] = new string[] {"[Asso Type]","[PK Asso Type ID]","[Type Name]"};
            Table[4] = new string[] {"[Authorization Status]","[PK Authorization Status ID]","[Authorization Status]"};
            Table[5] = new string[] {"[Boolean]","[PK Boolean ID]","[YesNo]"};
            Table[6] = new string[] {"[Branch]","[PK Branch ID]","[Name]"};
            Table[7] = new string[] {"[Consistency Check]","[PK Consistency Check ID]","[Message]"};
            Table[8] = new string[] {"[Country]","[PK Country ID]","[Country Name]"};
            Table[9] = new string[] {"[Deterministic Effects]","[PK Deterministic Effects ID]","[Deterministic Effects]"};
            Table[10] = new string[] {"[Dose Extremity Organ List]","[PK Dose Extremity Organ List ID]","[Extremity or Organ]"};
            Table[11] = new string[] {"[Dose Limits]","[PK Dose Limits ID]","[Limit Name]"};
            Table[12] = new string[] {"[Emergency Response Level]","[PK Emergency Response Level ID]","[Emergency Response Level]"};
            Table[13] = new string[] {"[Event Cause]","[PK Event Cause ID]","[Cause]"};
            Table[14] = new string[] {"[Extent of Event]","[PK Extent of Event ID]","[Extent of Event]"};
            Table[15] = new string[] {"[Facility Status]","[PK Facility Status ID]","[Status Name]"};
            Table[16] = new string[] {"[Field]","[PK Field ID]","[Name]"};
            Table[17] = new string[] {"[Generator Type]","[PK Generator Type ID]","[Type Name]"};
            Table[18] = new string[] {"[Health Consequences]","[PK Health Consequences ID]","[Health Consequences]"};
            Table[19] = new string[] {"[Inspection Status]","[PK Inspection Status ID]","[Inspection Status]"};
            Table[20] = new string[] {"[Monitoring Status]","[PK Monitoring Status ID]","[Status]"};
            Table[21] = new string[] {"[Non-Compliance]","[PK Non-Compliance ID]","[Name]"};
            Table[22] = new string[] {"[Non-Compliance Category]","[PK Non-Compliance Category ID]","[Category Name]"};
            Table[23] = new string[] {"[Non-Compliance Major Category]","[PK Non-Compliance Major Category ID]","[Major Category Name]"};
            Table[24] = new string[] {"[Officer Task]","[PK Officer Task ID]","[Officer Task]"};
            Table[25] = new string[] {"[Package Categories]","[PK Package Categories ID]","[Package Category Name]"};
            Table[26] = new string[] {"[Person Status]","[PK Person Status ID]","[Status]"};
            Table[27] = new string[] {"[Physical Barrier]","[PK Physical Barrier ID]","[Barrier Name]"};
            Table[28] = new string[] {"[Physical Form]","[PK Physical Form ID]","[Form]"};
            Table[29] = new string[] {"[Practice]","[PK Practice ID]","[Practice Name]"};
            Table[30] = new string[] {"[Practice Category]","[PK Practice Category ID]","[Category Name]"};
            Table[31] = new string[] {"[Professional Degree]","[PK Professional Degree ID]","[Degree Name]"};
            Table[32] = new string[] {"[Propagator - Consistency Checks]","[PK_SQL_ID]","[Message]"};
            Table[33] = new string[] {"[Radiological Concequences]","[PK Radiological Concequences ID]","[Event type description]"};
            Table[34] = new string[] {"[Regulatory Reference Status]","[PK Regulatory Reference Status ID]","[Status]"};
            Table[35] = new string[] {"[Regulatory Reference Type]","[PK Regulatory Reference Type ID]","[Type]"};
            Table[36] = new string[] {"[Report Type]","[PK Report Type ID]","[Report Type]"};
            Table[37] = new string[] {"[Response]","[PK Response ID]","[Name]"};
            Table[38] = new string[] {"[Sealed Category]","[PK Sealed Category ID]","[Category Name]"};
            Table[39] = new string[] {"[Security Group]","[PK Security Group ID]","[Name]"};
            Table[40] = new string[] {"[Sex]","[PK Sex ID]","[Sex]"};
            Table[41] = new string[] {"[Source Status]","[PK Source Status ID]","[Source Status]"};
            Table[42] = new string[] {"[System - Messages]","[PK_SQL_ID]","[Message Language Text]"};
            Table[43] = new string[] {"[System - Search]","[PK_SQL_ID]","[Search Item]"};
            Table[44] = new string[] {"[System - Search]","[PK_SQL_ID]","[Search Field]"};
            Table[45] = new string[] {"[Time Unit]","[PK Time Unit ID]","[Interval]"};
            Table[46] = new string[] {"[Transfer Type]","[PK Transfer Type ID]","[Transfer Type Name]"};
            Table[47] = new string[] {"[Transport Mode]","[PK Transport Mode ID]","[Transport Mode]"};
            Table[48] = new string[] {"[Treatment]","[PK Treatment ID]","[Treatment]"};
            Table[49] = new string[] {"[Wave Form]","[PK Wave Form ID]","[Wave Name]"};

            int SelectedLanguage = Convert.ToInt32(Context.Parameters["SelectedLanguage"]);
            string[] Language = new string[] { "Arabic", "English", "French", "Russian", "Spanish" };

            string connectionString1 = string.Format("Data Source={0};Initial Catalog={1};Integrated Security=True;", Context.Parameters["db"], Context.Parameters["catalog"]);
            using (SqlConnection connection = new SqlConnection(connectionString1))
            {
                SqlCommand com = new SqlCommand("", connection);
                SqlDataAdapter da = new SqlDataAdapter();
                System.Data.DataTable dtLanguageValues = new System.Data.DataTable();

                connection.Open();

                com.Parameters.Add("@TableName", System.Data.SqlDbType.NVarChar).Value = "";
                com.Parameters.Add("@PrimaryKey", System.Data.SqlDbType.Int).Value = 0;
                com.Parameters.Add("@TranslationString", System.Data.SqlDbType.NVarChar).Value = "";
                
                for (int i = 1; i <= 49; i++)
                {
                    com.CommandText = "SELECT [FK ID], " + Language[SelectedLanguage - 1] + " AS TranslationString " + "FROM [Translation Install Values] " + "WHERE [Table Name] = @TableName";
                    com.Parameters["@TableName"].Value = Table[i][0];

                    dtLanguageValues.Clear();
                    da.SelectCommand = com;
                    da.Fill(dtLanguageValues);

                    com.CommandText = "UPDATE " + Table[i][0] + " SET " + Table[i][2] + " = @TranslationString " + "WHERE " + Table[i][1] + " = @PrimaryKey";
                    
                    foreach (System.Data.DataRow row in dtLanguageValues.Rows)
                    {
                        if ((Table[i][0] == "[System - Search]") & (Table[i][2] == "[Search Field]"))
                           com.Parameters["@PrimaryKey"].Value = (int)row["FK ID"] - 100;
                        else
                            com.Parameters["@PrimaryKey"].Value = row["FK ID"];
                        com.Parameters["@TranslationString"].Value = row["TranslationString"];
                        com.ExecuteNonQuery();
                    }
                }
            }
        }
    }
}